package com.mqtt.model;

import lombok.Data;
import java.io.Serializable;
import java.util.Date;

/**
 * MQTT消息
 */
@Data
public class MqttMessage implements Serializable {
    
    private static final long serialVersionUID = 1L;
    
    /**
     * 消息ID
     */
    private String messageId;
    
    /**
     * 主题
     */
    private String topic;
    
    /**
     * 消息内容
     */
    private String payload;
    
    /**
     * QoS级别
     */
    private Integer qos;
    
    /**
     * 是否保留消息
     */
    private Boolean retained;
    
    /**
     * 设备ID
     */
    private String deviceId;
    
    /**
     * 设备类型
     */
    private String deviceType;
    
    /**
     * 消息类型
     */
    private String messageType;
    
    /**
     * 时间戳
     */
    private Date timestamp;
    
    /**
     * 处理状态
     */
    private String processStatus;
    
    /**
     * 重试次数
     */
    private Integer retryCount;
    
    /**
     * 错误信息
     */
    private String errorMessage;
}